package com.guchenbo.example.dubbo.cluster;

import org.apache.dubbo.rpc.Invoker;
import org.apache.dubbo.rpc.RpcException;
import org.apache.dubbo.rpc.cluster.Cluster;
import org.apache.dubbo.rpc.cluster.Directory;

public class GcbCluster implements Cluster {

  @Override
  public <T> Invoker<T> join(Directory<T> directory) throws RpcException {
    return new ClusterInvoker(directory.getUrl(), directory.getInterface(),
        directory);
  }
}
